26f9d2395171d5a75091a8d45f101c1c449177f3,src/main/java/com/aol/cyclops2/internal/stream/ReactiveStreamX.java,ReactiveStreamX,subscribeAll,#Consumer#,577

Before Change



    @Override
    public void subscribeAll(final Consumer<? super T> action) {
        source.subscribeAll(action, this.defaultErrorHandler,()->{});

    }

After Change



    @Override
    public void subscribeAll(final Consumer<? super T> action) {
        if(async==Type.NO_BACKPRESSURE)
            source.subscribeAll(action, this.defaultErrorHandler,()->{});
        else
            source.subscribe(action, this.defaultErrorHandler,()->{}).request(Long.MAX_VALUE);

    }